51793149a04ee195796af325ebb298b933c053de,src/main/java/com/continuuity/data/operation/ttqueue/TTQueueNewOnVCTable.java,TTQueueNewOnVCTable,dequeue,#QueueConsumer#ReadPointer#,162

Before Change


    }

    // If QueueState is null, read the queue state from underlying storage.
    QueueState queueState = consumer.getQueueState();
    if(queueState == null) {
      queueState = dequeueStrategy.constructQueueState(consumer, config, readPointer);
      consumer.setQueueState(queueState);

After Change


    }

    // If QueueState is null, read the queue state from underlying storage.
    QueueStateImpl queueState = getQueueStateImpl(consumer.getQueueState());
    if(queueState == null) {
      queueState = dequeueStrategy.constructQueueState(consumer, config, readPointer);
      consumer.setQueueState(queueState);